package com.wjb.handler;

import org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler;
import org.springframework.stereotype.Component;

/**
 * @author : 王济彬
 * @date: 2025/5/27 - 05 - 27 - 23:50
 * @Description: com.wjb.handler
 * @version: 1.0
 */
@Component
public class CustomRabbitErrorHandler extends ConditionalRejectingErrorHandler {

    @Override
    public void handleError(Throwable t) {
        // 打印完整的异常信息
        t.printStackTrace();
        // 可选择记录日志
        logger.error("RabbitMQ Message消费失败", t);
        super.handleError(t);
    }
}
